//package com.sunye.kafka;
//
//
//import org.apache.kafka.clients.admin.NewTopic;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//@Configuration
//public class KafkaConfig {
//
//    // 创建一个名为topic1的Topic并设置分区数为8，分区副本（follower）数为2
//    @Bean
//    public NewTopic createTopic(){
//        return new NewTopic("topic1",8,(short)2);
//    }
//
//    // 如果要修改分区数，只需修改配置值重启项目即可
//    // 修改分区数并不会导致数据的丢失，但是分区数只能增大不能减小
//    @Bean
//    public NewTopic updateTopic(){
//        return new NewTopic("topic1",10,(short) 2);
//    }
//
//
//    // 创建一个名为topicWithCall的Topic并设置分区数为8，分区副本数为1
//    @Bean
//    public NewTopic createTopicWithCall(){
//        return new NewTopic("topicWithCall",10,(short)3);
//    }
//
//    //创建一个分区
//    @Bean
//    public NewTopic customizeTopic(){
//        return new NewTopic("customizeTopic",10,(short)2);
//    }
//
//
//    // 创建一个名为topicTrans的Topic并设置分区数为8，分区副本数为2
//    @Bean
//    public NewTopic createTopicTrans(){
//        return new NewTopic("topicTrans",8,(short)2);
//    }
//
//}
